bb9f0972c879967b9aaa8848b7f18067caabf87f,server/src/main/java/com/orientechnologies/orient/server/distributed/conflict/ODefaultReplicationConflictResolver.java,ODefaultReplicationConflictResolver,reset,#,193

Before Change


  @Override
  public ODocument reset() {
    ODatabaseRecordThreadLocal.INSTANCE.set((ODatabaseRecord) database);
    final int deleted = database.command(new OSQLSynchQuery<OIdentifiable>("delete from " + DISTRIBUTED_CONFLICT_CLASS));
    return new ODocument().field("result", deleted);
  }

After Change


  @Override
  public ODocument reset() {
    ODatabaseRecordThreadLocal.INSTANCE.set((ODatabaseRecord) database);
    final int deleted = (Integer) database.command(new OSQLSynchQuery<OIdentifiable>("delete from " + DISTRIBUTED_CONFLICT_CLASS))
        .execute();
    return new ODocument().field("result", deleted);
  }